home *** CD-ROM | disk | FTP | other *** search
/ The CICA Windows Explosion! / The CICA Windows Explosion! - Disc 2.iso / demo / igps_102.zip / SOCKET.H < prev    next >
C/C++ Source or Header  |  1994-11-30  |  7KB  |  226 lines
  1. ////////////////////////////////////////////////////////////////////////////////////
  2. // Internet Global Phone Project
  3. // socket.h : definitions of the CSocketOwner base classes                             
  4. //
  5. // See Dr. Dobb's Journal text for a description of the classes.  These C++
  6. // classes attempt to provide a more 'humane' way to program Winsock by shielding
  7. // much of the complexity and providing a higher level abstraction based on
  8. // the client/server/listener paradigm made popular in BSD networking.
  9. //
  10. // Source for implementation of these base classes are not provided as they tie
  11. // closely to the WSNETWRK library.  Link with SOCKLIB.LIB to use these
  12. // classes.
  13. ////////////////////////////////////////////////////////////////////////////////////
  14. // Copyright (c) 1993-1994    microWonders Inc.  All rights reserved.
  15. //                                                                         
  16. // AN OPEN INVITION TO BUILD UPON AND CONTRIBUTE TO THE PUBLIC TECHNOLOGY POOL:
  17. // You are encouraged to redistribute, and build upon the technologies presented 
  18. // in this source module and the accompanying article in Dr. Dobb's Journal provided 
  19. // all the conditions listed in the MUSTREAD.TXT file, included with this 
  20. // distribution, are met.
  21. ////////////////////////////////////////////////////////////////////////////////////
  22.  
  23. #define WS_TALKCLIENT    3
  24. #define WSTALKLISTENER    2  
  25. #define WSTALKCHILD        4
  26.  
  27. #define MIN_UINTERVAL    3000
  28. //#define WSTALKBUFFERSIZE 255
  29.  
  30. #define WSTALKFAILED    1   
  31. #define WSTALKLISFAILED    6       
  32. #define WSTALKBACK        0
  33. #define WSTALKBEGIN        0x0300
  34. #define WSCHILDCLOSED    7 
  35. #define WSTALKLISCONNECT 8
  36. #define WSTALKNEWCHILD    5
  37.  
  38.  
  39. #define TCP_PROTOCOL    "tcp"   
  40. #define TALK_SERVICE    "intertalker"
  41.  
  42. // legacy construct for prototype of echo server
  43. //
  44. typedef struct
  45. {
  46.   WORD  seq;
  47.   DWORD time;
  48.   DWORD done;
  49.   char  szBuffer[80];
  50. } ECHOPACKET, near *PECHOPACKET, far *LPECHOPACKET;
  51.  
  52. #define WSTALKBUFFERSIZE sizeof(ECHOPACKET)  
  53.  
  54. void __export WINAPI UniversalCSockOwnerNotify(WSSOCKET iEntry, int iEvent, int iError);
  55.  
  56. class CSocketOwner : public CObject
  57. {
  58. public: 
  59.     CSocketOwner() {}           
  60.     ~CSocketOwner() {} 
  61.     WSSOCKET GetSafeSocket() const {return (m_socket); } 
  62.     BOOL SetSafeSocket(WSSOCKET sock) {m_socket = sock; return TRUE;}
  63.     void Notify(WSSOCKET, int, int);
  64.     virtual void OnConnected(int, int) {}
  65.     virtual void OnSendCompleted(int, int) {}
  66.     virtual void OnReceiveCompleted(int, int) {}
  67.     virtual void OnTimerExpired(int, int)  {}
  68.     virtual void OnDisconnected(int, int)  {}
  69.     virtual void OnOtherMsgs(int, int)  {}     
  70.  
  71. public:  
  72.   int         m_iType;  
  73.   NOTIFYPROC  m_fNotifyProc;  
  74. protected:
  75.     WSSOCKET m_socket;
  76. protected:                                      
  77.     // wrap the WSNETWRK library
  78.     BOOL Accept(LPWSADDRESS addr, LPWSPORTID portid);
  79.     void CallBack(int i, int j);
  80.     BOOL CancelIO(void);
  81.      BOOL  wConnect(LPCSTR lp, WSPORTID portid);
  82.     BOOL ConnectTo(WSADDRESS waddr, WSPORTID portid);
  83.     WSSOCKET CreateSocket(int i, int j, WSPORTID portid, UINT k, HWND hWnd, NOTIFYPROC lpProc);
  84.     BOOL   CreateTimer(UINT i);
  85. public:        
  86.     BOOL DestroySocket(void);
  87. public:
  88.     LPVOID   GetSockMemory(void);
  89. protected:        
  90.     BOOL   KillTimer(void);
  91.     int  LastRecvLength(void);
  92.     HWND  MyCallBack(void);
  93.     int   MyLastError(void);
  94.     BOOL   Recv( LPSTR lp, int i);
  95.     BOOL   RecvFrom( LPSTR lp, int i, LPWSADDRESS lpaddr, LPWSPORTID lpid);
  96.     BOOL Send( LPCSTR lp1, int i);
  97.     BOOL SendTo( LPCSTR lp1, int i, WSADDRESS waddr, WSPORTID portid);
  98. public:                        
  99.     WSADDRESS MyAddress(void);
  100.     // this can also be used to create new server socket... via listener 
  101.     WSSOCKET AttachSocket(HSOCK hSock, UINT i, HWND hWnd, NOTIFYPROC lpf);
  102.     int Checksum(unsigned short far * fp, int i);
  103.     WSADDRESS GetHostByName(LPCSTR name);
  104.     int  GetHostName(LPSTR lp , int i);
  105.        int GetProtocolByName(LPCSTR lp);
  106.     WSPORTID   GetServiceByName(LPCSTR lp1, LPCSTR lp2);
  107.     int  GetServiceByPort(WSPORTID portid, LPCSTR lp1, LPSTR lp2, int i);
  108.     long HToNL(long ld);
  109.     long      NToHL(long lg);
  110.  
  111. // Attributes
  112. public: 
  113. #ifdef _DEBUG
  114.     virtual void AssertValid() const {}
  115.     virtual void Dump(CDumpContext& dc) const {}
  116. #endif
  117. };
  118.  
  119. // NOT USED WITHIN IGP
  120. class CSockClient: public CSocketOwner
  121. { 
  122.  
  123. public: // create from serialization only
  124.     CSockClient(); 
  125.     ~CSockClient(); 
  126.     // overload to connect by name or address
  127.     WSSOCKET Connect( UINT prot, LPCSTR, WSPORTID, UINT, HWND,NOTIFYPROC, UINT);
  128.     WSSOCKET Connect(UINT prot, WSADDRESS, WSPORTID, UINT, HWND, NOTIFYPROC, UINT);
  129.     BOOL SetTimeout(WSSOCKET, UINT);
  130.     BOOL End();
  131.  
  132.     void ResetStats(void); 
  133.     
  134.     virtual void OnConnected(int, int);
  135.     virtual void OnSendCompleted(int, int);
  136.     virtual void OnReceiveCompleted(int, int);
  137.     virtual void OnTimerExpired(int, int);       
  138.     virtual void OnDisconnected(int, int);
  139.     
  140.     void OnSocketSelect();
  141.     void OnTimer();
  142.     void OnCloseSocket();
  143.     
  144.     void SendData();
  145.     void ReadLine();
  146.  
  147.  
  148. private:  
  149.   BOOL        m_bConnected;
  150.   WSADDRESS   m_lAddress;
  151.   WSPORTID    m_uPort;
  152.   WSADDRESS   m_lRecvAddress;
  153.   WSPORTID    m_uRecvPort;
  154.   UINT        m_uAttempts;
  155.   UINT        m_uFailures;
  156.   DWORD       m_dMin;
  157.   DWORD       m_dAvg;
  158.   DWORD       m_dMax;
  159.   long double m_ldTotalTime;
  160.   UINT        m_uSequence;
  161.   BOOL        m_bInProgress;
  162.   UINT        m_uInterval;
  163.   UINT        m_uLateReplies;
  164.   UINT        m_uLimit;
  165.  
  166.   UINT        m_uErrorCount;
  167.   ECHOPACKET  m_Packet;
  168.  
  169. private:       
  170.     void WriteData();
  171.     void DestroyConnection();
  172.     
  173. #ifdef _DEBUG
  174.     virtual void AssertValid() const;
  175.     virtual void Dump(CDumpContext& dc) const;
  176. #endif
  177.  
  178. };
  179.                       
  180. // NOT USED WITHIN IGP                      
  181. class CSockServer: public CSocketOwner
  182. {                                
  183. public:
  184.     CSockServer(); 
  185.     ~CSockServer();
  186.     int Create(void);
  187.     WSSOCKET StartServer(HWND, NOTIFYPROC);
  188.     WSSOCKET EndServer(WSSOCKET);
  189.  
  190.     virtual void OnOtherMsgs(int, int);
  191.     virtual void OnReceiveCompleted(int, int);
  192.     virtual void OnSendCompleted(int, int);
  193.     virtual void OnDisconnected(int, int);
  194.  
  195. private:
  196.   WSPORTID    m_uPort;
  197.   WSADDRESS   m_lAddress;
  198.   char        m_szBuffer[WSTALKBUFFERSIZE];    
  199. #ifdef _DEBUG
  200.     virtual void AssertValid() const;
  201.     virtual void Dump(CDumpContext& dc) const;
  202. #endif
  203.  
  204. }; 
  205.  
  206.  
  207. class CSockListenServer: public CSocketOwner
  208. {                                
  209. public:
  210.     CSockListenServer(); 
  211.     ~CSockListenServer();
  212.     int Create(void);  
  213.     WSSOCKET StartListener(LPCSTR, WSPORTID, LPWSADDRESS,  HWND, NOTIFYPROC);
  214.     BOOL EndListener(); 
  215.  
  216.     virtual void OnOtherMsgs(int, int);
  217.                                              
  218. protected:
  219.  
  220. #ifdef _DEBUG
  221.     virtual void AssertValid() const;
  222.     virtual void Dump(CDumpContext& dc) const;
  223. #endif
  224.     
  225. };
  226.